package com.tnt.springbootrabbitmq.consumer.topicexchange;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.util.Map;

/**
 * @Description 消费者
 * @Author zhuangxl
 * @Date 2021-01-24 20:36
 */
@Slf4j
@Component
public class TopicConsumer1 {

    @RabbitListener(queues = "topicExchangQueue1")
    public void process(Map<String, Object> paramsMap){

        log.info("DirectConsumer1接收到队列消息：{}", paramsMap.toString());

    }
}
